package david.java.flink_sql.common;

/**
 * @Description:
 * @Author: ZhaoDawei
 * @Date: Create in 10:05 上午 2022/3/25
 */
public class Constant {
    public static String OUT_PUT_TABLE = "CREATE TABLE OutPutTable (\n" +
            "  name STRING,\n" +
            "  score INT\n" +
            ") PARTITIONED BY (name) WITH (\n" +
            "  'connector' = 'filesystem',           -- required: specify the connector\n" +
            "  'path' = '/Users/zhaodawei/test/OutPutTable',  -- required: path to a directory\n" +
            "  'format' = 'JSON'                     -- required: file system connector requires to specify a format,\n" +
            ")";
}
